# 生产者
from celery_task import send_email, send_msg

for i in range(20):
    result = send_email.delay("lufei")
    print(result.id)
    result2 = send_msg.delay("nrduo")
    print(result2.id)